//package com.itbuka.config;
//
//import org.springframework.amqp.core.*;
//import org.springframework.beans.factory.annotation.Qualifier;
//import org.springframework.context.annotation.Bean;
//import org.springframework.context.annotation.Configuration;
//
//@Configuration
//public class RabbitConfig {
//    //队列
//    public static final String AD_QUEUE = "ad.queue";
//    //商品队列
//
//    //交换机
//    public static final String AD_EXCHANGE = "ad.exchange";
//    //商品交换机
//
//
//    //声明队列
//    /*
//     *   new Queue(QUEUE_EMAIL,true,false,false)
//     *   durable="true" 持久化 rabbitmq重启的时候不需要创建新的队列
//     *   auto-delete 表示消息队列没有在使用时将被自动删除 默认是false
//     *   exclusive  表示该消息队列是否只在当前connection生效,默认是false
//     */
//    @Bean(AD_QUEUE)
//    public Queue AD_QUEUE() {
//        return new Queue(AD_QUEUE);
//    }
//
//
//    //声明交换机
//    @Bean(AD_EXCHANGE)
//    public Exchange AD_EXCHANGE() {
//        //durable(true) 持久化，mq重启之后交换机还在
//        return ExchangeBuilder.fanoutExchange(AD_EXCHANGE).durable(true).build();
//    }
//
//
//    //队列绑定交换机，指定routingKey
//    @Bean
//    public Binding RABBIT_EXCHANGE_QUEUE(@Qualifier(AD_QUEUE) Queue queue, @Qualifier(AD_EXCHANGE) Exchange exchange) {
//        return BindingBuilder.bind(queue).to(exchange).with(AD_QUEUE).noargs();
//    }
//
//}
//
